--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
meshchatx/src/backend/telephone_manager.py 014e463527af2d3aa5ea4fc10f98d2e705093fbb (014e4635) Text, 10.97 KB
Tff7b72import T7ee787asyncio
Tff7b72import T7ee787os
Tff7b72import T7ee787time
Tff7b72import T7ee787RNS
Tff7b72from T7ee787LXST Tff7b72import Te6edf3Telephone
Tff7b72class T56d364TeeTb4b4b4:
Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3sinkTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffsinks Tff7b72= Tb4b4b4[Te6edf3sinkTb4b4b4]
Tff7b72def Td2a8ffadd_sinkTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3sinkTb4b4b4)Tb4b4b4:
Tff7b72if Te6edf3sink Tff7b72not Tff7b72in Tff7b72selfTff7b72.Td2a8ffsinksTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffsinksTff7b72.Td2a8ffappendTb4b4b4(Te6edf3sinkTb4b4b4)
Tff7b72def Td2a8ffremove_sinkTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3sinkTb4b4b4)Tb4b4b4:
Tff7b72if Te6edf3sink Tff7b72in Tff7b72selfTff7b72.Td2a8ffsinksTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffsinksTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3sinkTb4b4b4)
Tff7b72def Td2a8ffhandle_frameTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3frameTb4b4b4, Te6edf3sourceTb4b4b4)Tb4b4b4:
Tff7b72for Te6edf3sink Tff7b72in Tff7b72selfTff7b72.Td2a8ffsinksTb4b4b4:
Tff7b72tryTb4b4b4:
Te6edf3sinkTff7b72.Td2a8ffhandle_frameTb4b4b4(Te6edf3frameTb4b4b4, Te6edf3sourceTb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffTee: Error in sink handle_frame: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72def Td2a8ffcan_receiveTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3from_sourceTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:
Tff7b72return Tffa657anyTb4b4b4(Te6edf3sinkTff7b72.Td2a8ffcan_receiveTb4b4b4(Te6edf3from_sourceTb4b4b4) Tff7b72for Te6edf3sink Tff7b72in Tff7b72selfTff7b72.Td2a8ffsinksTb4b4b4)
Tff7b72class T56d364TelephoneManagerTb4b4b4:
T8b949e# LXST Status Constants for reference:
T8b949e# 0: STATUS_BUSY
T8b949e# 1: STATUS_REJECTED
T8b949e# 2: STATUS_CALLING
T8b949e# 3: STATUS_AVAILABLE
T8b949e# 4: STATUS_RINGING
T8b949e# 5: STATUS_CONNECTING
T8b949e# 6: STATUS_ESTABLISHED
Tff7b72def Tff7b72__init__Tb4b4b4(
Tff7b72selfTb4b4b4, Te6edf3identityTb4b4b4: Te6edf3RNSTff7b72.Td2a8ffIdentityTb4b4b4, Te6edf3config_managerTff7b72=Tff7b72NoneTb4b4b4, Te6edf3storage_dirTff7b72=Tff7b72NoneTb4b4b4, Te6edf3dbTff7b72=Tff7b72None
Tb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffidentity Tff7b72= Te6edf3identity
Tff7b72selfTff7b72.Td2a8ffconfig_manager Tff7b72= Te6edf3config_manager
Tff7b72selfTff7b72.Td2a8ffstorage_dir Tff7b72= Te6edf3storage_dir
Tff7b72selfTff7b72.Td2a8ffdb Tff7b72= Te6edf3db
Tff7b72selfTff7b72.Td2a8ffget_name_for_identity_hash Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffrecordings_dir Tff7b72= Tb4b4b4(
Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Te6edf3storage_dirTb4b4b4, Ta5d6ff"Ta5d6ffrecordingsTa5d6ff"Tb4b4b4) Tff7b72if Te6edf3storage_dir Tff7b72else Tff7b72None
Tb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8ffrecordings_dirTb4b4b4:
Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrecordings_dirTb4b4b4, Te6edf3exist_okTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72selfTff7b72.Td2a8fftelephone Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffon_ringing_callback Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffon_established_callback Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffon_ended_callback Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffcall_start_time Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffcall_status_at_end Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffcall_is_incoming Tff7b72= Tff7b72False
T8b949e# Manual mute overrides in case LXST internal muting is buggy
Tff7b72selfTff7b72.Td2a8fftransmit_muted Tff7b72= Tff7b72False
Tff7b72selfTff7b72.Td2a8ffreceive_muted Tff7b72= Tff7b72False
Tff7b72selfTff7b72.Td2a8ffinitiation_status Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffinitiation_target_hash Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffon_initiation_status_callback Tff7b72= Tff7b72None
Tf0883e@property
Tff7b72def Td2a8ffis_recordingTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
T8b949e# Disabled for now
Tff7b72return Tff7b72False
Tff7b72def Td2a8ffinit_telephoneTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephone Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:
Tff7b72return
Tff7b72selfTff7b72.Td2a8fftelephone Tff7b72= Te6edf3TelephoneTb4b4b4(Tff7b72selfTff7b72.Td2a8ffidentityTb4b4b4)
T8b949e# Disable busy tone played on caller side when remote side rejects, or doesn't answer
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffset_busy_tone_timeTb4b4b4(T79c0ff0Tb4b4b4)
T8b949e# Set initial profile from config
Tff7b72if Tff7b72selfTff7b72.Td2a8ffconfig_managerTb4b4b4:
Te6edf3profile_id Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfig_managerTff7b72.Td2a8fftelephone_audio_profile_idTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffswitch_profileTb4b4b4(Te6edf3profile_idTb4b4b4)
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffset_ringing_callbackTb4b4b4(Tff7b72selfTff7b72.Td2a8ffon_telephone_ringingTb4b4b4)
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffset_established_callbackTb4b4b4(Tff7b72selfTff7b72.Td2a8ffon_telephone_call_establishedTb4b4b4)
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffset_ended_callbackTb4b4b4(Tff7b72selfTff7b72.Td2a8ffon_telephone_call_endedTb4b4b4)
Tff7b72def Td2a8ffteardownTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephone Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffteardownTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8fftelephone Tff7b72= Tff7b72None
Tff7b72def Td2a8ffregister_ringing_callbackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3callbackTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffon_ringing_callback Tff7b72= Te6edf3callback
Tff7b72def Td2a8ffregister_established_callbackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3callbackTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffon_established_callback Tff7b72= Te6edf3callback
Tff7b72def Td2a8ffregister_ended_callbackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3callbackTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffon_ended_callback Tff7b72= Te6edf3callback
Tff7b72def Td2a8ffon_telephone_ringingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3caller_identityTb4b4b4: Te6edf3RNSTff7b72.Td2a8ffIdentityTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffcall_start_time Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffcall_is_incoming Tff7b72= Tff7b72True
Tff7b72if Tff7b72selfTff7b72.Td2a8ffon_ringing_callbackTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffon_ringing_callbackTb4b4b4(Te6edf3caller_identityTb4b4b4)
Tff7b72def Td2a8ffon_telephone_call_establishedTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3caller_identityTb4b4b4: Te6edf3RNSTff7b72.Td2a8ffIdentityTb4b4b4)Tb4b4b4:
T8b949e# Update start time to when it was actually established for duration calculation
Tff7b72selfTff7b72.Td2a8ffcall_start_time Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
T8b949e# Recording disabled for now due to stability issues with LXST
T8b949e# if self.config_manager and self.config_manager.call_recording_enabled.get():
T8b949e# self.start_recording()
Tff7b72if Tff7b72selfTff7b72.Td2a8ffon_established_callbackTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffon_established_callbackTb4b4b4(Te6edf3caller_identityTb4b4b4)
Tff7b72def Td2a8ffon_telephone_call_endedTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3caller_identityTb4b4b4: Te6edf3RNSTff7b72.Td2a8ffIdentityTb4b4b4)Tb4b4b4:
T8b949e# Capture status just before ending if possible, or use the last known status
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffcall_status_at_end Tff7b72= Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffcall_status
Tff7b72if Tff7b72selfTff7b72.Td2a8ffon_ended_callbackTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffon_ended_callbackTb4b4b4(Te6edf3caller_identityTb4b4b4)
Tff7b72def Td2a8ffstart_recordingTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
T8b949e# Disabled for now as LXST does not have a Tee to use
Tff7b72pass
Tff7b72def Td2a8ffstop_recordingTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
T8b949e# Disabled for now
Tff7b72pass
Tff7b72def Td2a8ffannounceTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3attached_interfaceTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffannounceTb4b4b4(Te6edf3attached_interfaceTff7b72=Te6edf3attached_interfaceTb4b4b4)
Tff7b72def Td2a8ff_update_initiation_statusTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3statusTb4b4b4, Te6edf3target_hashTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffinitiation_status Tff7b72= Te6edf3status
Tff7b72if Te6edf3target_hash Tff7b72is Tff7b72not Tff7b72None Tff7b72or Te6edf3status Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffinitiation_target_hash Tff7b72= Te6edf3target_hash
Tff7b72if Tff7b72selfTff7b72.Td2a8ffon_initiation_status_callbackTb4b4b4:
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffon_initiation_status_callbackTb4b4b4(
Tff7b72selfTff7b72.Td2a8ffinitiation_statusTb4b4b4, Tff7b72selfTff7b72.Td2a8ffinitiation_target_hash
Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffTelephoneManager: Error in initiation status callback: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4,
Tb4b4b4)
Tff7b72async Tff7b72def Td2a8ffinitiateTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4: Tffa657bytesTb4b4b4, Te6edf3timeout_secondsTb4b4b4: Tffa657int Tff7b72= T79c0ff15Tb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephone Tff7b72is Tff7b72NoneTb4b4b4:
Te6edf3msg Tff7b72= Ta5d6ff"Ta5d6ffTelephone is not initializedTa5d6ff"
Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Te6edf3msgTb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffbusy Tff7b72or Tff7b72selfTff7b72.Td2a8ffinitiation_statusTb4b4b4:
Te6edf3msg Tff7b72= Ta5d6ff"Ta5d6ffTelephone is already in useTa5d6ff"
Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Te6edf3msgTb4b4b4)
Te6edf3destination_hash_hex Tff7b72= Te6edf3destination_hashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_update_initiation_statusTb4b4b4(Ta5d6ff"Ta5d6ffResolving identity...Ta5d6ff"Tb4b4b4, Te6edf3destination_hash_hexTb4b4b4)
Tff7b72tryTb4b4b4:
T8b949e# Find destination identity
Te6edf3destination_identity Tff7b72= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffrecallTb4b4b4(Te6edf3destination_hashTb4b4b4)
T8b949e# If identity not found, check if it's a destination hash in our announces
Tff7b72if Te6edf3destination_identity Tff7b72is Tff7b72None Tff7b72and Tff7b72selfTff7b72.Td2a8ffdbTb4b4b4:
Te6edf3announce Tff7b72= Tff7b72selfTff7b72.Td2a8ffdbTff7b72.Td2a8ffannouncesTff7b72.Td2a8ffget_announce_by_hashTb4b4b4(Te6edf3destination_hash_hexTb4b4b4)
Tff7b72if Te6edf3announceTb4b4b4:
Te6edf3identity_hash Tff7b72= Tffa657bytesTff7b72.Td2a8fffromhexTb4b4b4(Te6edf3announceTb4b4b4[Ta5d6ff"Ta5d6ffidentity_hashTa5d6ff"Tb4b4b4]Tb4b4b4)
Te6edf3destination_identity Tff7b72= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffrecallTb4b4b4(Te6edf3identity_hashTb4b4b4)
Tff7b72if Te6edf3destination_identity Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_update_initiation_statusTb4b4b4(Ta5d6ff"Ta5d6ffDiscovering path/identity...Ta5d6ff"Tb4b4b4)
Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffrequest_pathTb4b4b4(Te6edf3destination_hashTb4b4b4)
T8b949e# Wait for identity to appear
Te6edf3start_wait Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Tff7b72while Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72- Te6edf3start_wait Tff7b72< Te6edf3timeout_secondsTb4b4b4:
Tff7b72await Te6edf3asyncioTff7b72.Td2a8ffsleepTb4b4b4(T79c0ff0.5Tb4b4b4)
Te6edf3destination_identity Tff7b72= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffrecallTb4b4b4(Te6edf3destination_hashTb4b4b4)
Tff7b72if Te6edf3destination_identityTb4b4b4:
Tff7b72break
Tff7b72if Tff7b72selfTff7b72.Td2a8ffdbTb4b4b4:
Te6edf3announce Tff7b72= Tff7b72selfTff7b72.Td2a8ffdbTff7b72.Td2a8ffannouncesTff7b72.Td2a8ffget_announce_by_hashTb4b4b4(
Te6edf3destination_hash_hex
Tb4b4b4)
Tff7b72if Te6edf3announceTb4b4b4:
Te6edf3identity_hash Tff7b72= Tffa657bytesTff7b72.Td2a8fffromhexTb4b4b4(Te6edf3announceTb4b4b4[Ta5d6ff"Ta5d6ffidentity_hashTa5d6ff"Tb4b4b4]Tb4b4b4)
Te6edf3destination_identity Tff7b72= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffrecallTb4b4b4(Te6edf3identity_hashTb4b4b4)
Tff7b72if Te6edf3destination_identityTb4b4b4:
Tff7b72break
Tff7b72if Te6edf3destination_identity Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_update_initiation_statusTb4b4b4(Tff7b72NoneTb4b4b4, Tff7b72NoneTb4b4b4)
Te6edf3msg Tff7b72= Ta5d6ff"Ta5d6ffDestination identity not foundTa5d6ff"
Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Te6edf3msgTb4b4b4)
Tff7b72if Tff7b72not Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffhas_pathTb4b4b4(Te6edf3destination_hashTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_update_initiation_statusTb4b4b4(Ta5d6ff"Ta5d6ffRequesting path...Ta5d6ff"Tb4b4b4)
Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffrequest_pathTb4b4b4(Te6edf3destination_hashTb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_update_initiation_statusTb4b4b4(Ta5d6ff"Ta5d6ffDialing...Ta5d6ff"Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffcall_start_time Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffcall_is_incoming Tff7b72= Tff7b72False
T8b949e# Use a thread for the blocking LXST call
Tff7b72await Te6edf3asyncioTff7b72.Td2a8ffto_threadTb4b4b4(Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffcallTb4b4b4, Te6edf3destination_identityTb4b4b4)
Tff7b72return Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffactive_call
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_update_initiation_statusTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffFailed: Tffd700{Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4)
Tff7b72await Te6edf3asyncioTff7b72.Td2a8ffsleepTb4b4b4(T79c0ff3Tb4b4b4)
Tff7b72raise
Tff7b72finallyTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_update_initiation_statusTb4b4b4(Tff7b72NoneTb4b4b4, Tff7b72NoneTb4b4b4)
Tff7b72def Td2a8ffmute_transmitTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4:
T8b949e# Manual override as LXST internal muting can be buggy
Tff7b72if Tffa657hasattrTb4b4b4(Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4, Ta5d6ff"Ta5d6ffaudio_inputTa5d6ff"Tb4b4b4) Tff7b72and Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffaudio_inputTb4b4b4:
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffaudio_inputTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffFailed to stop audio input for mute: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
T8b949e# Still call the internal method just in case it does something useful
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffmute_transmitTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4: T8b949e# noqa: S110
Tff7b72pass
Tff7b72selfTff7b72.Td2a8fftransmit_muted Tff7b72= Tff7b72True
Tff7b72def Td2a8ffunmute_transmitTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4:
T8b949e# Manual override as LXST internal muting can be buggy
Tff7b72if Tffa657hasattrTb4b4b4(Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4, Ta5d6ff"Ta5d6ffaudio_inputTa5d6ff"Tb4b4b4) Tff7b72and Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffaudio_inputTb4b4b4:
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffaudio_inputTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffFailed to start audio input for unmute: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERROR
Tb4b4b4)
T8b949e# Still call the internal method just in case
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffunmute_transmitTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4: T8b949e# noqa: S110
Tff7b72pass
Tff7b72selfTff7b72.Td2a8fftransmit_muted Tff7b72= Tff7b72False
Tff7b72def Td2a8ffmute_receiveTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4:
T8b949e# Manual override as LXST internal muting can be buggy
Tff7b72if Tffa657hasattrTb4b4b4(Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4, Ta5d6ff"Ta5d6ffaudio_outputTa5d6ff"Tb4b4b4) Tff7b72and Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffaudio_outputTb4b4b4:
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffaudio_outputTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffFailed to stop audio output for mute: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
T8b949e# Still call the internal method just in case
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffmute_receiveTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4: T8b949e# noqa: S110
Tff7b72pass
Tff7b72selfTff7b72.Td2a8ffreceive_muted Tff7b72= Tff7b72True
Tff7b72def Td2a8ffunmute_receiveTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4:
T8b949e# Manual override as LXST internal muting can be buggy
Tff7b72if Tffa657hasattrTb4b4b4(Tff7b72selfTff7b72.Td2a8fftelephoneTb4b4b4, Ta5d6ff"Ta5d6ffaudio_outputTa5d6ff"Tb4b4b4) Tff7b72and Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffaudio_outputTb4b4b4:
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffaudio_outputTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffFailed to start audio output for unmute: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERROR
Tb4b4b4)
T8b949e# Still call the internal method just in case
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephoneTff7b72.Td2a8ffunmute_receiveTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4: T8b949e# noqa: S110
Tff7b72pass
Tff7b72selfTff7b72.Td2a8ffreceive_muted Tff7b72= Tff7b72False
──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────